package cn.doitedu.demo1;

import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

public class Rule_2_Calculator implements RuleCalculator{
    @Override
    public void init(RuntimeContext runtimeContext,String ruleParamJson) {
        System.out.println("我是规则2的初始化");
    }

    @Override
    public void calc(UserEvent userEvent, Collector<Message> out) {
        System.out.println("我是规则2的运算方法: "+userEvent);
    }
}
